┌────────────────────────────────┐ │ ░░░ ░░▓ ░▓▓ ███ ▓▓░ ▓░░ │ │ ~ M O O N ~ │ └────────────────────────────────┘

prd-web-01.centraldc.gr

✎ EDIT FILE

EDITING: Loop.php

<?php declare(strict_types=1);

/*
 * This file is part of Composer.
 *
 * (c) Nils Adermann <naderman@naderman.de>
 *     Jordi Boggiano <j.boggiano@seld.be>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Composer\Util;

use Symfony\Component\Console\Helper\ProgressBar;
use React\Promise\PromiseInterface;

/**
 * @author Jordi Boggiano <j.boggiano@seld.be>
 */
class Loop
{
    /** @var HttpDownloader */
    private $httpDownloader;
    /** @var ProcessExecutor|null */
    private $processExecutor;
    /** @var array<int, array<PromiseInterface<mixed>>> */
    private $currentPromises = [];
    /** @var int */
    private $waitIndex = 0;

public function __construct(HttpDownloader $httpDownloader, ?ProcessExecutor $processExecutor = null)
    {
        $this->httpDownloader = $httpDownloader;
        $this->httpDownloader->enableAsync();

$this->processExecutor = $processExecutor;
        if ($this->processExecutor) {
            $this->processExecutor->enableAsync();
        }
    }

public function getHttpDownloader(): HttpDownloader
    {
        return $this->httpDownloader;
    }

public function getProcessExecutor(): ?ProcessExecutor
    {
        return $this->processExecutor;
    }

/**
     * @param array<PromiseInterface<mixed>> $promises
     */
    public function wait(array $promises, ?ProgressBar $progress = null): void
    {
        $uncaught = null;

\React\Promise\all($promises)->then(
            static function (): void {
            },
            static function (\Throwable $e) use (&$uncaught): void {
                $uncaught = $e;
            }
        );

// keep track of every group of promises that is waited on, so abortJobs can
        // cancel them all, even if wait() was called within a wait()
        $waitIndex = $this->waitIndex++;
        $this->currentPromises[$waitIndex] = $promises;

if ($progress) {
            $totalJobs = 0;
            $totalJobs += $this->httpDownloader->countActiveJobs();
            if ($this->processExecutor) {
                $totalJobs += $this->processExecutor->countActiveJobs();
            }
            $progress->start($totalJobs);
        }

$lastUpdate = 0;
        while (true) {
            $activeJobs = 0;

$activeJobs += $this->httpDownloader->countActiveJobs();
            if ($this->processExecutor) {
                $activeJobs += $this->processExecutor->countActiveJobs();
            }

if ($progress && microtime(true) - $lastUpdate > 0.1) {
                $lastUpdate = microtime(true);
                $progress->setProgress($progress->getMaxSteps() - $activeJobs);
            }

if (!$activeJobs) {
                break;
            }
        }

// as we skip progress updates if they are too quick, make sure we do one last one here at 100%
        if ($progress) {
            $progress->finish();
        }

unset($this->currentPromises[$waitIndex]);
        if (null !== $uncaught) {
            throw $uncaught;
        }
    }

public function abortJobs(): void
    {
        foreach ($this->currentPromises as $promiseGroup) {
            foreach ($promiseGroup as $promise) {
                // to support react/promise 2.x we wrap the promise in a resolve() call for safety
                \React\Promise\resolve($promise)->cancel();
            }
        }
    }
}

CANCEL

Name	Type	Size	Modified	Actions
↩ ..	DIR	—	—
📁 Http/	DIR	—	2026-04-15 15:13
📄 AuthHelper.php	PHP	16 KB	2026-01-29 00:00	EDIT
📄 Bitbucket.php	PHP	9.7 KB	2026-01-29 00:00	EDIT
📄 ComposerMirror.php	PHP	2.3 KB	2026-01-29 00:00	EDIT
📄 ConfigValidator.php	PHP	9.5 KB	2026-01-29 00:00	EDIT
📄 ErrorHandler.php	PHP	4 KB	2026-01-29 00:00	EDIT
📄 Filesystem.php	PHP	30.5 KB	2026-01-29 00:00	EDIT
📄 Forgejo.php	PHP	3.9 KB	2026-01-29 00:00	EDIT
📄 ForgejoRepositoryData.php	PHP	1.6 KB	2026-01-29 00:00	EDIT
📄 ForgejoUrl.php	PHP	1.8 KB	2026-01-29 00:00	EDIT
📄 Git.php	PHP	29.1 KB	2026-01-29 00:00	EDIT
📄 GitHub.php	PHP	9.8 KB	2026-01-29 00:00	EDIT
📄 GitLab.php	PHP	12.4 KB	2026-01-29 00:00	EDIT
📄 Hg.php	PHP	3.6 KB	2026-01-29 00:00	EDIT
📄 HttpDownloader.php	PHP	17.9 KB	2026-01-29 00:00	EDIT
📄 IniHelper.php	PHP	1.6 KB	2026-01-29 00:00	EDIT
📄 Loop.php	PHP	3.4 KB	2026-01-29 00:00	EDIT
📄 MetadataMinifier.php	PHP	650 B	2026-01-29 00:00	EDIT
📄 NoProxyPattern.php	PHP	10.6 KB	2026-01-29 00:00	EDIT
📄 PackageInfo.php	PHP	1.1 KB	2026-01-29 00:00	EDIT
📄 PackageSorter.php	PHP	4.1 KB	2026-01-29 00:00	EDIT
📄 Perforce.php	PHP	18.7 KB	2026-01-29 00:00	EDIT
📄 Platform.php	PHP	10.7 KB	2026-01-29 00:00	EDIT
📄 ProcessExecutor.php	PHP	17.9 KB	2026-01-29 00:00	EDIT
📄 RemoteFilesystem.php	PHP	27.2 KB	2026-01-29 00:00	EDIT
📄 Silencer.php	PHP	2 KB	2026-01-29 00:00	EDIT
📄 StreamContextFactory.php	PHP	9.4 KB	2026-01-29 00:00	EDIT
📄 Svn.php	PHP	9.6 KB	2026-01-29 00:00	EDIT
📄 SyncHelper.php	PHP	2.7 KB	2026-01-29 00:00	EDIT
📄 Tar.php	PHP	1.7 KB	2026-01-29 00:00	EDIT
📄 TlsHelper.php	PHP	7 KB	2026-01-29 00:00	EDIT
📄 Url.php	PHP	5.2 KB	2026-01-29 00:00	EDIT
📄 Zip.php	PHP	3.3 KB	2026-01-29 00:00	EDIT

Η σελίδα δεν βρέθηκε – BIO Προσαρμογή

Ωπα! Αυτή η σελίδα δε βρέθηκε.

Φαίνεται ότι δεν βρέθηκε τίποτα σε αυτή τη θέση. Ίσως να προσπαθήσετε να ψάξετε για κάτι άλλο;